e4b5535ea186352ece0304f79e5a65535ff8c205,cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/templates/etl/batch/ETLMapReduce.java,ETLMapReduce,prepareSource,#MapReduceContext#ETLStage#,88

Before Change



  private void prepareSource(MapReduceContext context, ETLStage sourceStage) throws Exception {
    String sourcePluginId = context.getRuntimeArguments().get(Constants.Source.PLUGINID);
    BatchSource source = context.newPluginInstance(sourcePluginId);
    BatchSourceContext sourceContext = new MapReduceSourceContext(context, mrMetrics, sourcePluginId);
    LOG.info("Source Stage : {}", sourceStage);
    LOG.info("Source Class : {}", source.getClass().getName());

After Change


  }

  private void prepareSource(MapReduceContext context, ETLStage sourceStage) throws Exception {
    sourcePluginId = context.getRuntimeArguments().get(Constants.Source.PLUGINID);
    batchSource = context.newPluginInstance(sourcePluginId);
    BatchSourceContext sourceContext = new MapReduceSourceContext(context, mrMetrics, sourcePluginId);
    LOG.info("Source Stage : {}", sourceStage);
    LOG.info("Source Class : {}", batchSource.getClass().getName());